package queue

import (
	"fmt"
	"gitee.com/worklz/yunj-blog-go-micro-common/log"
)

// InitQueue 初始化队列任务
func InitQueue(queues []QueueInterface) {
	for _, q := range queues {
		if err := q.SetStatus(q.DefaultStartStatus()); err != nil {
			panic(fmt.Sprintf("%s状态设置异常: %v", q.LogPrefix(), err))
		}
	}
	if err := JobSchedulerInstance().Start(queues); err != nil {
		panic(fmt.Sprintf("队列任务执行失败: %v", err))
	}
	log.Info("队列任务执行开始...")
}
